package org.zhadoop.stream.cql.hooks;

/**
 * 执行器前后的钩子
 * 
 * 一个数据反序列化之后，数据检查之前
 * 一个发生在应用程序提交之前，应用程序检查之前
 * @author zwd
 *
 */
public interface ExecutorHook {
	/**
	 * 物理计划解析之后，数据检查之前执行的钩子
	 * @param physicPlanApplication
	 */
	void preExecute(org.zhadoop.stream.api.Application physicPlanApplication);
	
	/**
	 * 应用程序提交之前执行的钩子
	 * @param submitApplication
	 */
	void preSubmit(org.zhadoop.streaming.application.Application submitApplication);
}
